package io.a.flink

import org.apache.flink.api.scala.ExecutionEnvironment
//隐式转换
import org.apache.flink.api.scala._

object WordCount {
  def main(args: Array[String]): Unit = {
    //获取Flink运行环境
    val environment = ExecutionEnvironment.getExecutionEnvironment
    //注意 readTextFile路径填你自己的文件路径。
    val testDataSet = environment.readTextFile("d:/1.txt")
    //可以理解testDataSet为一个RDD
    //groupby(0)意思是以元组第一个为key进行分组，sum(1)是对元组第二个位置数据进行累加。
    val result = testDataSet.flatMap(_.split(" ")).map((_, 1)).groupBy(0).sum(1)
    result.print()
  }
}